package com.example.myspringboot.kafka;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

/**
 * @author zheng
 */
@Service
public class KafkaMessageConsumer {

    @KafkaListener(topics = "test-messages")
    public void receiveAdminMessage(String message) {
        System.err.println("Received message: " + message);
    }

}
